package com.dtwave.cfstreaming.udf;

import org.apache.flink.table.functions.ScalarFunction;

public class StrPares extends ScalarFunction {
    public String eval(String str){
        if(str != null)
        {
            return str;
        }else {
            return "";
        }
    }
}
